6ef5d7fa9f92a051738ff57f2102bd7041ae3443,camel-jms/src/test/java/org/apache/camel/jms/JmsRouteTest.java,JmsRouteTest,testJmsRoute,#,33

Before Change


        container.addComponent("activemq", jmsComponent(connectionFactory));

        // lets add some routes
        container.routes(new RouteBuilder() {
            public void configure() {
                from("jms:activemq:FOO.BAR").to("jms:activemq:FOO.BAR");
            }
        });
    }
}

After Change


        container.addComponent("activemq", jmsComponent(template));

        // lets add some routes
        container.routes(new RouteBuilder() {
            public void configure() {
                from("jms:activemq:test.a").to("jms:activemq:test.b");
                from("jms:activemq:test.b").process(new Processor<JmsExchange>() {
                    public void onExchange(JmsExchange exchange) {
                        System.out.println("Received exchange: " + exchange.getRequest());
                    }
                });
            }
        });

        // now lets fire in a message
        Endpoint<JmsExchange> endpoint = container.endpoint("jms:activemq:test.a");